package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.arithmetic.common.Cn6EngineDataThresholdInfo;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;

public interface LoadCn6ThresholdInfoService extends Serializable {
    JavaPairRDD<String, Cn6EngineDataThresholdInfo> getCn6ThresholdInfoRdd(SparkSession spark, JavaSparkContext jsc);
}
